Sourced from github.com/rabbitmq/rabbitmq-stream-go-client's releases.

v1.5.0

Version 1.5

What's Changed

Please read before updating.

This version focuses on stability during the reconnection and introduces the dynamic send. There are no breaking changes, but deprecations:

• BatchPublishingDelay int is not used anymore.

Dynamic send

Dynamic send improves the latency when the traffic is low; for example, with 50 msg per second, there is ~3ms latency:

go run perftest.go --rate 50 --async-send
Published     42.9 msg/s | Confirmed     42.9 msg/s |  Consumed     42.9 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     43.8 msg/s | Confirmed     43.8 msg/s |  Consumed     43.8 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     44.4 msg/s | Confirmed     44.4 msg/s |  Consumed     44.4 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     45.0 msg/s | Confirmed     45.0 msg/s |  Consumed     45.0 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 2 ms

With the 1.4.x is~ 90ms (the aggregation timeout)

go run perftest.go --rate 50 --async-send
Published     44.4 msg/s | Confirmed     44.4 msg/s |  Consumed     44.4 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 88 ms
Published     45.0 msg/s | Confirmed     45.0 msg/s |  Consumed     45.0 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 89 ms
Published     45.5 msg/s | Confirmed     45.5 msg/s |  Consumed     45.5 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 90 ms

Enhancements

• Update to Golang 1.22
• Update the readers and random function deprecated
• Introduce the dynamic send in rabbitmq/rabbitmq-stream-go-client#367
• Increase the stability during the reconnection for Reliable Producers and Reliable Consumers in rabbitmq/rabbitmq-stream-go-client#367 and rabbitmq/rabbitmq-stream-go-client#371
• Performance improvement on unconfirmed map by @​hiimjako in rabbitmq/rabbitmq-stream-go-client#374
• Set TCP parameters only if they are greater than 0 by @​hiimjako in rabbitmq/rabbitmq-stream-go-client#375
• Add limit to the unconfirmed messages @​Gsantomaggio rabbitmq/rabbitmq-stream-go-client#378
• Close TCP connection in case of CRC fails @​Gsantomaggio in rabbitmq/rabbitmq-stream-go-client#378
• Replace map with syncmap @​Gsantomaggio in rabbitmq/rabbitmq-stream-go-client#377

Bug Fixes

• Fix: rabbitmq/rabbitmq-stream-go-client#365

... (truncated)

• 4f1b90b rabbitmq-stream-go-client v1.5.0
• 9aab047 Add example with reliable* (#379)
• 83553a8 rabbitmq-stream-go-client v1.5.0-rc.1
• 7a3d780 Add limit to the unconfirmed messages (#378)
• 51c3dca replace map with syncmap (#377)
• feb6917 wait metadata (#376)
• 2d3b96e fix: set TCP parameters only if they are greater than 0 (#375)
• fb01bca Performance improvement on unconfirmed map (#374)
• d52e281 rabbitmq-stream-go-client v1.5.0-beta.1
• 31dbf96 Consumer improvements for 1.5 (#371)
• Additional commits viewable in compare view

You can trigger Dependabot actions by commenting on this PR:

• @dependabot rebase will rebase this PR
• @dependabot recreate will recreate this PR, overwriting any edits that have been made to it
• @dependabot merge will merge this PR after your CI passes on it
• @dependabot squash and merge will squash and merge this PR after your CI passes on it
• @dependabot cancel merge will cancel a previously requested merge and block automerging
• @dependabot reopen will reopen this PR if it is closed
• @dependabot close will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
• @dependabot show <dependency name> ignore conditions will show all of the ignore conditions of the specified dependency
• @dependabot ignore this major version will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this minor version will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this dependency will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)